a4911a6cd5a14e471c9fc44972f1983c59345318,src/freenet/node/FNPPacketMangler.java,FNPPacketMangler,processOutgoingOrRequeue,#MessageItem[]#PeerNode#boolean#boolean#,996

Before Change


                for(int i=0;i<messageData.length;i++) {
                	MessageItem mi = newMsgs[i];
					mi_name = (mi.msg == null ? "(not a Message)" : mi.msg.getSpec().getName());
                	if(mi.ctrCallback != null) {
                		mi.ctrCallback.sentBytes(messageData[i].length + 
                				1 + (HEADERS_LENGTH_MINIMUM / messageData.length));
                		// FIXME rounding issues
                	}
                    if(mi.cb != null) {
                    	for(int j=0;j<mi.cb.length;j++) mi.cb[j].sent();
                    }
                }
            } catch (NotConnectedException e) {

After Change


            try {
                innerProcessOutgoing(messageData, 0, messageData.length, length, pn, neverWaitForPacketNumber, callbacks, alreadyReportedBytes);
                for(int i=0;i<messageData.length;i++) {
                	MessageItem mi = newMsgs[i];
					mi_name = (mi.msg == null ? "(not a Message)" : mi.msg.getSpec().getName());
					mi.onSent(messageData[i].length + 1 + (HEADERS_LENGTH_MINIMUM / messageData.length));
                }
            } catch (NotConnectedException e) {
                Logger.normal(this, "Caught "+e+" while sending messages ("+mi_name+") to "+pn.getPeer()+requeueLogString);